Skip to content

SerialReplayLatestSignalAsync class

Defined in

Namespace: ReactiveUI.Primitives.Async.Signals Assembly: ReactiveUI.Primitives.Async.Core.dll Full name: ReactiveUI.Primitives.Async.Signals.SerialReplayLatestSignalAsync<T> Modifiers: public sealed

Summary

View source

        Represents an asynchronous Signal that replays only the latest value to new subscribers and ensures that
        notifications are delivered to observers in a serial, thread-safe manner.
        

Applies to

net10.0, net10.0-browserwasm1.0, net10.0-desktop1.0, net9.0, net9.0-browserwasm1.0, net9.0-desktop1.0, net8.0, net8.0-ios17.5, net8.0-maccatalyst17.5, net8.0-macos14.2, net8.0-macos14.5, net8.0-tvos17.2, netstandard2.1, net462, net481, net471

Class hierarchy
classDiagram
class SerialReplayLatestSignalAsync~T~
class ISignalAsync~T~ {
    <>
}
ISignalAsync~T~ <|.. SerialReplayLatestSignalAsync~T~
class IObserverAsync~T~ {
    <>
}
IObserverAsync~T~ <|.. SerialReplayLatestSignalAsync~T~
class IAsyncDisposable {
    <>
}
IAsyncDisposable <|.. SerialReplayLatestSignalAsync~T~
class IObservableAsync~T~ {
    <>
}
IObservableAsync~T~ <|.. SerialReplayLatestSignalAsync~T~

Implements: ISignalAsync, IObserverAsync, IAsyncDisposable, IObservableAsync

Remarks

This Signal is designed for scenarios where only the most recent value is relevant to subscribers. When a new observer subscribes, it immediately receives the latest value (if any) and then all subsequent notifications. All observer notifications are performed asynchronously and in a serial order, ensuring thread safety. This type is suitable for use cases where replaying only the latest value is desired, such as event streams or state broadcasts.

Constructors

NameSummary
.ctorRepresents an asynchronous Signal that replays only the latest value to new subscribers and ensures that notifications are delivered to observers in a serial, thread-safe manner.

Methods

NameSummary
OnNextAsyncAsynchronously processes the next value in the sequence.
OnErrorResumeAsyncHandles the specified error and resumes asynchronous processing, if possible.
OnCompletedAsyncPerforms asynchronous completion logic in response to the specified result.
DisposeAsync
SubscribeAsyncSubscribes the specified asynchronous observer to receive notifications from the observable sequence.
Inherited members